package com.xxk.rocket.star.core.message;

import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import com.alibaba.rocketmq.common.message.MessageExt;
import com.xxk.rocket.star.core.context.ConsumeContext;

public interface IProcessMessageConsume {

  //正常继续
  int SUCCESS = 0;
  //不理会后面的处理器直接消费消息
  int CONSUME = 1;
  //中断处理
  int BREAK = 2;

  int processConsume(ConsumeContext consumeContext, MessageExt messageExt,
                     ConsumeConcurrentlyContext consumeConcurrentlyContext, Object[] args)
          throws Throwable;
}
